from airflow.operators.python import PythonOperator

from jms.dwd.dwd_cn_address_warehouse_es_dt.esaddress2hive import jms_find_address

jms_dwd__dwd_cn_address_warehouse_es_dt = PythonOperator(
    task_id='jms_dwd__dwd_cn_address_warehouse_es_dt',
    python_callable=jms_find_address,
    pool='threecode_es',
    pool_slots=1,
    email=['yushuo@jtexpress.com','yl_bigdata@yl-scm.com'],
    op_args=['{{ var.value.env }}', '{{ execution_date | cst_ds_nodash }}', '{{ execution_date | date_add(1) | cst_ds_nodash }}'])
    #op_args=['{{ var.value.env }}', '20210520', '20210521'])